package com.yun.zhong.fu.usercenter.rocketmq;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Author RenPu
 * @Date 2021/1/4 17:45
 * @Version 1.0
 * @Description: 实现自定义接口消息的消费
 **/
public interface MySink {

    String MY_INPUT = "my_input";

    @Input(MY_INPUT)
    SubscribableChannel input();


}
